package com.durian.base.rxhttp.await

import kotlinx.coroutines.withTimeout

/**
 * 说明：请求超时处理
 * <p/>
 * 作者：Fanly
 * <p/>
 * 类型：Class
 * <p/>
 * 时间：2020/04/25 18:06
 * <p/>
 * 版本：version 1.0
 */
internal class AwaitTimeout<T>(
        private val iAwait: IAwait<T>,
        private var timeoutMillis: Long = 0L
) : IAwait<T> {
    override suspend fun await(): T = withTimeout(timeoutMillis) { iAwait.await() }
}